package data.source
//
//import com.ruozedata.flink.utils.{RuozedataFlinkKafkaUtils, RuozedataRedisSink}
import org.apache.flink.api.java.utils.ParameterTool
//import org.apache.flink.api.scala._
//
///**
// * @author PK哥
// **/
object FlinkKafkaRedisApp {
  def main(args: Array[String]): Unit = {

//
//    val stream = RuozedataFlinkKafkaUtils.createKafkaStream(parameters)
//    val result = stream.flatMap(_.split(","))
//      .map((_,1))
//      .keyBy(x=>x._1)
//      .sum(1)
//
//    result.print()
//
//    result.map(x => ("ruozedata-wc", x._1, x._2.toLong)).addSink(new RuozedataRedisSink)
//    RuozedataFlinkKafkaUtils.env.execute(getClass.getCanonicalName)
//
  }
}
